package cn.itcast.dmp.tags
import org.apache.commons.lang3.StringUtils
import org.apache.spark.sql.Row

object Tags4ChannelMaker extends TagsMaker{
  override def make(row: Row, dic: Map[String, String]): Map[String, Double] = {
    // a. 依据渠道字段获取对应的值
    val channelid = row.getAs[String]("channelid")
    // b. 是否为空
if(StringUtils.isNotBlank(channelid)){
  Map(s"CH@channelid" -> 1.0)
}else{
  Map[String,Double]()

}


  }
}
